package cn.com.yang.mq;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;

/**
 * 
 * TODO
 * @author yangyijin
 * @since 2024年7月22日-下午7:03:34
 */
@Service
public class RocketMQMultiProducer {
	@Autowired
	@Qualifier("producerGroup1")
	private DefaultMQProducer producerGroup1;

	// 使用producerGroup1发送消息
	// ...

	@Autowired
	@Qualifier("producerGroup2")
	private DefaultMQProducer producerGroup2;

	// 使用producerGroup2发送消息
	// ...
}
